package com.example.listener;


import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.stereotype.Component;

/**
 * 消息监听者，这个在dispatcher-servlet.xml配置文件中被声明，被作为组件使用自动加载到内存中
 */
@Component
public class TestMessageListener implements MessageListener {

    /** 接收到消息事件 */
    @Override
    public void onMessage(Message message) {
        /** 获取消息内容 */
        String receivedMessage = new String(message.getBody());
        System.out.println("Received message: " + receivedMessage);
        // 在这里处理消息
        /** 具体的业务逻辑 ，比如写入数据库 */
    }
}